﻿using Contracts;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace CommandProcessors
{
    public abstract class CommandProcessor : IObserver<ICommand>
    {
        public CommandProcessor(ICommandStore commandPersist)
        {
            this.commandPersist = commandPersist;
        }

        public void OnCompleted()
        {
            throw new NotImplementedException();
        }

        public void OnError(Exception error)
        {
            throw new NotImplementedException();
        }

        public void OnNext(ICommand value)
        {
            throw new NotImplementedException();
        }

        protected ICommandStore commandPersist;
    }
}
